package com.at.functions5;

import com.at.bean.WaterSensor;
import org.apache.flink.api.common.functions.FilterFunction;

/**
 * @author huangchao E-mail:fengquan8866@163.com
 * @version 创建时间：2024/9/25 15:02
 */
public class FilterFunctionImpl2 implements FilterFunction<WaterSensor> {
    public String id;

    public FilterFunctionImpl2(String id) {
        this.id = id;
    }

    @Override
    public boolean filter(WaterSensor value) throws Exception {
        return id.equals(value.getId());
    }
}
